/*
 ***************************************************************************************
 * All rights Reserved, Designed By RTF
 * @Title:  MessageConsumer.java   
 * @Package com.rtf.repair.mq.common
 * @Description: 消费者接口，在此处理消费业务   
 * @author: 司福林
 * @date:   2020-10-17 16:46:31   
 * @version V1.0 
 * @Copyright: 2020 RTF. All rights reserved.
 * 注意：本内容仅限于公司内部使用，禁止外泄以及用于其他的商业目
 *  ---------------------------------------------------------------------------------- 
 * 文件修改记录
 *     文件版本：         修改人：             修改原因：
 ***************************************************************************************
 */
package com.rtf.framework.mq.common;

import java.util.List;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.rocketmq.common.message.MessageExt;

public interface BatchMessageConsumer {

	/**
	 * On message.
	 *
	 * @param message the message
	 * @return the object
	 */
	public boolean onMessage(List<byte[]> messages);

	/**
	 * kafka消费 会调用onMessage(String tag, byte[] message);
	 * 
	 */
	public boolean onMessageKafka(List<ConsumerRecord<String, byte[]>> records);

	/**
	 * rocketmq消费会调用onMessage(String tag, byte[] message);
	 *  
	 */
	public boolean onMessageRocket(List<MessageExt> records);
}
